package com.yugao.fintech.draper.message.queue.support;

import com.yugao.fintech.draper.message.queue.message.AbstractMessage;

/**
 * 消息拦截器
 */
public interface MessageQueueInterceptor {
	/**
	 * 发送前拦截
	 */
	void sendMessageBefore(AbstractMessage message);

	/**
	 * 发送后拦截
	 */
	void sendMessageAfter(AbstractMessage message);

	/**
	 * 消费前拦截
	 */
	void consumeMessageBefore(AbstractMessage message);

	/**
	 * 消费后拦截
	 */
	void consumeMessageAfter(AbstractMessage message);

}
